package com.sven.hello.mq;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.cloud.stream.messaging.Sink;
import org.springframework.messaging.MessageChannel;

/**
 * 创建一个将input消息通道作为输出通道的接口
 * （这里发出的消息，会被input通道接收，需要SinkReceiver修改）
 */
public interface SinkSender {

    // //将输出通道绑定到名为input的主题中
    // @Output(Sink.INPUT)
    // MessageChannel output();
}
